package com.cyf.activemq.service.bean;

import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

/**
 * 消息队列
 */
@Component
public class QueueList {

	/**
	 * 业务1队列
	 */
	public static final String QUEUE_SEND = "queue_toc_tob";
	public static final String TOPIC_RECEIVE = "topic_tob_toc";
	public static final String QUEUE_RECEIVE_PAY = "queue_pay";
	/**
	 * queue消息：toc->tob
	 * @return
	 */
	@Bean(name = "queueSend")
	public javax.jms.Queue queueSend() {
		return new ActiveMQQueue(QUEUE_SEND);
	}

	/**
	 * 业务2队列
	 */
	//public static final String BUSINESS2 = "activemq.queue2";
	/**
	 * queue消息：toc->tob
	 * @return
	 */
	@Bean(name = "queueSendPay")
	public javax.jms.Queue queueSendPay() {
		return new ActiveMQQueue(QUEUE_RECEIVE_PAY);
	}
}